package jdbc;

import java.sql.ResultSet;
import java.sql.SQLException;

public class DireccionJDBC {

	public static void insertardireccion(String tipo, String nombre,
			Integer numero, Integer puerta, Integer cp) throws SQLException {
		conexion.con();
		String query = ("Insert into direccion (tipo_via, nombre_via, numero, puerta,cp) values ('"
				+ tipo
				+ "','"
				+ nombre
				+ "',"
				+ numero
				+ ","
				+ puerta
				+ ","
				+ cp + ");");

		if (!DireccionJDBC.comprobardireccion(tipo,nombre,numero,puerta,cp)) {
			conexion.insertar(query);
		} else {
			System.out.println("Ya existe en la base de datos");
		}
		conexion.cerrarconexion();

	}

	public static boolean comprobardireccion(String tipo, String nombre,
			Integer numero, Integer puerta, Integer cp) throws SQLException {

		boolean resul = false;
		ResultSet c = conexion
				.crearconsulta("Select * from direccion where tipo_via='"
						+ tipo + "' AND nombre_via='" + nombre
						+ "' AND numero=" + numero + " AND puerta=" + puerta
						+ " AND cp=" + cp + ";");
		if (c.next()) {
			resul = true;
		}

		return resul;
	}
	
	public static Integer consultardireccion(String tipo, String nombre,
			Integer numero, Integer puerta, Integer cp) throws SQLException {
		Integer iddireccion = null;
		conexion.con();
		
		if(comprobardireccion(tipo, nombre, numero, puerta, cp)){
			ResultSet c = conexion
			.crearconsulta("Select id_direccion from direccion where tipo_via='"
					+ tipo + "' AND nombre_via='" + nombre
					+ "' AND numero=" + numero + " AND puerta=" + puerta
					+ " AND cp=" + cp + ";");
			
			while (c.next()) {
				iddireccion = c.getInt("id_direccion");
			}
			
			
		}
		conexion.cerrarconexion();
		return iddireccion;

	}
}
